package com.queue.server.execution;

import com.queue.common.message.Message;
import io.netty.channel.Channel;

public interface Execution {
    /**
     * 执行操作（消费，推送，签收）
     * @param message
     * @param channel
     */
    void exec(Message message, Channel channel);

    /**
     * 返回当前策略支持的消息类型
     * @return
     */
    int getType();
}
